home *** CD-ROM | disk | FTP | other *** search
/ All for Cell Phones: Sony Ericsson / Sony-Ericsson 2004.iso / Java / ClienteChat / Cliente Chat.jar / com / xibaro / chat / Conexion.class (.txt) < prev    next >
Encoding:
Java Class File  |  2002-04-23  |  2.1 KB  |  81 lines

  1. package com.xibaro.chat;
  2.  
  3. import java.io.IOException;
  4. import javax.microedition.io.Connector;
  5. import javax.microedition.io.Datagram;
  6. import javax.microedition.io.DatagramConnection;
  7.  
  8. public class Conexion extends Thread {
  9.    private String server;
  10.    private String port;
  11.    private Cliente jefe;
  12.    private DatagramConnection socket;
  13.    private String dir;
  14.    private boolean seguir;
  15.  
  16.    public Conexion(Cliente var1, String var2, String var3) {
  17.       this.jefe = var1;
  18.       this.server = var2;
  19.       this.port = var3;
  20.       this.dir = "datagram://" + var2 + ":" + var3;
  21.       this.seguir = true;
  22.    }
  23.  
  24.    public boolean inicia() {
  25.       boolean var1 = false;
  26.  
  27.       try {
  28.          this.socket = (DatagramConnection)Connector.open(this.dir);
  29.       } catch (Exception var3) {
  30.          this.jefe.mensajeEstado("Error estableciendo conexi├│n");
  31.          var1 = true;
  32.       }
  33.  
  34.       if (!var1) {
  35.          ((Thread)this).start();
  36.          return true;
  37.       } else {
  38.          return false;
  39.       }
  40.    }
  41.  
  42.    public void run() {
  43.       for(Datagram var1 = null; this.seguir; this.jefe.recibido(var1)) {
  44.          try {
  45.             var1 = this.socket.newDatagram(this.socket.getMaximumLength());
  46.             this.socket.receive(var1);
  47.          } catch (IOException var4) {
  48.             this.jefe.mensajeEstado("Error de I/O al recibir");
  49.          } catch (IllegalArgumentException var5) {
  50.             this.jefe.mensajeEstado("Error al construir datagrama en recpci├│n");
  51.          }
  52.       }
  53.  
  54.    }
  55.  
  56.    public void parar() {
  57.       this.seguir = false;
  58.    }
  59.  
  60.    public void envia(String var1) {
  61.       try {
  62.          Datagram var2 = this.socket.newDatagram(var1.getBytes(), var1.getBytes().length, this.dir);
  63.          this.socket.send(var2);
  64.       } catch (IOException var3) {
  65.          this.jefe.mensajeEstado("Error I/O al enviar");
  66.       }
  67.  
  68.    }
  69.  
  70.    public void cerrar() {
  71.       this.seguir = false;
  72.  
  73.       try {
  74.          this.socket.close();
  75.       } catch (IOException var2) {
  76.       }
  77.  
  78.       this.socket = null;
  79.    }
  80. }
  81.